
# 创建一个celery应用对象，通常一个项目只需要创建一个celery应用就可以了
import os

from celery.app.base import Celery

# 指定django文件的配置文件
os.environ.setdefault("DJANGO_SETTINGS_MODULE", "meiduo_mall.settings.dev")

# 参数1 自定义名字
celery_app = Celery('meiduo', broker='redis://127.0.0.1:6379/15',
                    backend='redis://127.0.0.1:6379/14')

                    # backend 保存任务执行后的返回值
# celery_app = Celery('meiduo')  # 把配置都放到了config.py文件
# celery_app.config_from_object('celery_tasks.config')

# 扫描指定的包下面的任务函数
celery_app.autodiscover_tasks(['celery_tasks.sms', 'celery_tasks.email', 'celery_tasks.html'])
